Instance 0

Class510.future(final Callable<T> task){
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Future<T> future = executor.submit( task );
        executor.shutdown();
}


Instance 1

Class520.runInParallel(ExecutorService exec,Collection<Runnable> runnables)#0{
        for(Runnable runnable : runnables)
            exec.submit(runnable);
        exec.shutdown();
            exec.awaitTermination(1,TimeUnit.DAYS);
}


Instance 2

Class500.testConcurrentGroups()#2{
            executorService.submit(new TestProducer());
        executorService.shutdown();
        executorService.awaitTermination(5, TimeUnit.MINUTES);
}


Instance 3

Class650.run()#2{
                for (int i = 0; i < 100; i++) {
                    pool.submit(new TestRunnable(stripe, actual, i));
                }
                pool.shutdown();
}


Instance 4

Class440.MultiTaskSource(List<TaskSource> sources){
            ExecutorService service = Executors.newFixedThreadPool(sources.size());
            for (TaskSource source : sources) {
                service.submit(new TaskRunner(source));
            }
            service.shutdown();
}


Instance 5

Class460.AckProcessor(Map<String,PeerHandler> quorumMap,ClusterConfiguration cnf)#1{
        Executors.newSingleThreadExecutor(DaemonThreadFactory.FACTORY);
    ft = es.submit(this);
    es.shutdown();
}


Instance 6

Class100.internalNonBlockingStart(){
    ExecutorService executors = Executors.newFixedThreadPool( 1 );
    future = executors.submit( stackRunner );
    executors.shutdown();
}


Instance 7

Class330.createAsciidoctor()#1{
        asciidoctor = es.submit(new Callable<Asciidoctor>() {
            @Override
            public Asciidoctor call() throws Exception {
                return Asciidoctor.Factory.create();
            }
        });
        es.shutdown();
}


Instance 8

Class290.doConversion()#0{
    final Future<VideoFile> future = service.submit(new ConverterProcess(securityContext, inputVideo, outputFileName, outputSize));
    service.shutdown();
}


Instance 9

Class380.descendants(final Optional<NodeReadTrx> pRtx)#2{
      executor.submit(new GetDescendants());
      executor.shutdown();
}


Instance 10

Class470.start()#0{
      return executor.submit( createCoordinator() );
      executor.shutdown();
}


Instance 11

Class480.runAsyncInternal()#0{
        Crate.Tuple<ExecutorService, Boolean> crate = Concurrent.getManagedSingleThreadedExecutorService();
        jdkExecutor = !crate.getPayload2();
        ExecutorService executor = crate.getPayload1();
        executor.submit(callable);
        executor.shutdown();
}


Instance 12

Class490.compressAsynchronously(String nameOfFile2Compress,String nameOfCompressedFile,String innerEntryName)#0{
    Future<?> future = executor.submit(new CompressionRunnable(compressor,
        nameOfFile2Compress, nameOfCompressedFile, innerEntryName));
    executor.shutdown();
}